package com.hsj.mq.rabbitmq.topic;

import com.hsj.mq.Order2MQService;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 *    RabbitMq 使用
 *    1.依赖坐标   spring-boot-starter-amqp    这个不是名字 是 amqp
 *    2. 配置 url
 *    3. 创建queue 、 DirectExchange、 binding  对象  交给spring容器， 并用binding 绑定关系
 *    4. 使用 amqpTemplate 调用  方法即可
 *
 *
 */
//@Service
public class Order2MQRabbitTopicImpl implements Order2MQService {

//    @Autowired
    private AmqpTemplate amqpTemplate;

    @Override
    public void sendMessage2Mq(String id) {
        System.out.println("将订单信息  发送到 rabbitmq， id="+id);
        amqpTemplate.convertAndSend("topicExchange","topic.order.id",id);
    }

    @Override
    public String doMessage() {
        return null;
    }
}

